package com.lkx.kafka.monitor.service;

import java.util.Map;

public interface KafkaAdminService {


    /**
     * 创建Kafka主题
     * @param topicName 主题名称
     * @param partitions 分区数
     * @param replicas 副本数
     * @param retentionMs 消息保留时间(毫秒)
     */
    public void createTopic(String topicName, int partitions, int replicas, long retentionMs);

    /**
     * 删除Kafka主题
     * @param topicName 主题名称
     */
    public void deleteTopic(String topicName);

    /**
     * 保存Kafka配置
     * @param config 配置参数映射
     */
    public void saveKafkaConfig(Map<String, Object> config);


}
